package com.yi.wood.kafka.msg;

import org.springframework.stereotype.Component;
import org.springframework.util.concurrent.ListenableFutureCallback;

/**
 * Created by moyi on 2019/2/20 11:01
 *
 * @author moyi
 */
@Component
public class SendMsgCallBack implements ListenableFutureCallback<String> {

    @Override
    public void onSuccess(String o) {
        System.out.println("send success:"+o);
    }

    @Override
    public void onFailure(Throwable throwable) {
        System.out.println("send failed:"+throwable.getMessage());
    }
}
